//package com.open.source.demo;
//
//import com.open.source.MqConstant;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.kafka.annotation.KafkaHandler;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.messaging.handler.annotation.Header;
//import org.springframework.messaging.handler.annotation.Payload;
//import org.springframework.stereotype.Component;
//
///**
// * @author ZonLen since on 2022/8/17 下午1:15
// */
//@Slf4j
//@Component
//@KafkaListener(topics = MqConstant.TAX_TOPIC_DEMO, groupId = "YONG-YOU")
//public class DemoKafkaClassAnnotationListener {
//
//  @KafkaHandler
//  public void handler(@Payload String value,
//      @Header("host-ip") String hostIp,
//      @Header("trance-id") String tranceId,
//      @Header("sender-model") String senderModel
//  ) {
//    log.info("@KafkaHandler: host-ip={}, trance-id={}, sender-model＝{}, value ＝{}", hostIp,
//        tranceId, senderModel, value);
//  }
//
//}
